Arrow Resilience Kit/[root]/AdaptiveLimiter

AdaptiveLimiter

JS/TS-friendly facade over com.sorinirmies.arrow.resiliencekit.AdaptiveLimiter.

import { AdaptiveLimiter } from "arrow-resilience-kit";

const limiter = await AdaptiveLimiter.create({ initialLimit: 20 });
const result = await limiter.execute(() => downstream.call());

Types

Companion

object Companion

Functions

currentLimit

fun currentLimit(): Promise<Int>

Current concurrency limit.

execute

fun <T> execute(block: () -> Promise<T>): Promise<T>

Executes block, counting it toward the current concurrency limit and adapting the limit based on its outcome/latency.

statistics

fun statistics(): Promise<AdaptiveLimiterStatistics>

Current statistics snapshot.